/*
 ***************************************************************************************
 * All rights Reserved, Designed By RTF
 * @Title:  ConsumerProperties.java   
 * @Package com.rtf.repair.mq.common
 * @Description: 消费者属性   
 * @author: sfl
 * @date:   2020-10-17 17:28:22   
 * @version V1.0 
 * @Copyright: 2020 RTF. All rights reserved.
 * 注意：本内容仅限于公司内部使用，禁止外泄以及用于其他的商业目
 *  ---------------------------------------------------------------------------------- 
 * 文件修改记录
 *     文件版本：         修改人：             修改原因：
 ***************************************************************************************
 */
package com.rtf.framework.mq.common;

import java.util.Set;

import org.apache.rocketmq.common.MixAll;

import com.rtf.framework.mq.rocketmq.consumer.RocketConsumerConstant;

import lombok.Data;

/**
 *  
 *
 * @ClassName:  ConsumerProperties
 * @author: sfl
 * @date:   2020-10-17 17:28:22
 * @since:  v1.0
 */
@Data
public class ConsumerProperties {

	/** 消费者类型 */
	private String type;

	/** 生成消费者个数*/
	private int count = 1;

	/** 消费主体 rocketmq topic与tag之间使用~ */
	private Set<String> topics;

	/** 消费位置默认 0  */
	private int consumerWhere = CommonConstants.CONSUMER_OFFSET_LAST;

	/** 当 consumerWhere == 2消费位置根据时间定时 消费位置指定时间戳*/
	private long consumeTimestamp = System.currentTimeMillis() - 30 * 60 * 1000;

	/** 实例名字 */
	private String instanceName = "DEFAULT";

	/** 组名*/
	private String groupName = MixAll.DEFAULT_CONSUMER_GROUP;

	/** 消息处理类（实现{@link com.rtf.framework.mq.common.MessageConsumer}）或者 spring bean 名字*/
	private String handler;

	private String listener = RocketConsumerConstant.LISTENER_CUR;
}
